<?php

/**
 * 数据库连接文件
 */

/**
 * 数据库连接函数
 */
function my_connect($arr)
{
    $host = isset($arr['host']) ? $arr['host'] : 'localhost';
    $port = isset($arr['port']) ? $arr['port'] : '3306';
    $user = isset($arr['user']) ? $arr['user'] : 'root';
    $pass = isset($arr['pass']) ? $arr['pass'] : 'lianlin';
    $link = @ mysqli_connect("$host:$port", $user, $pass);
    if (!$link) {
        echo "数据库连接失败！<br />";
        echo "错误编号：", mysqli_errno($link), "<br />";
        echo "错误信息：", mysqli_error($link), '<br />';
        die;
    }
    return $link;
}

/**
 * 选择默认的字符集
 */
function my_charset($link, $arr)
{
    $charset = isset($arr['charset']) ? $arr['charset'] : 'utf8';
    $sql = "set names $charset";
    mysqli_query($link, $sql);
}
 /**
 * 选择默认的数据库
 */
function my_dbname($link, $arr)
{
    $dbname = isset($arr['dbname']) ? $arr['dbname'] : 'test';
    $sql = "use $dbname";
    mysqli_query($link, $sql);
}

// 加载配置文件
$config = include DIR_CONFIG . 'config.php';
$arr = $config['db'];

// 数据库连接三步曲
// 连接数据库
$link = my_connect($arr);
// 选择默认字符集
my_charset($link, $arr);
// 选择默认的数据库
my_dbname($link, $arr);
